﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ReactiveTest
{
    public sealed class SimpleObserver : IObserver<int>
    {
        void IObserver<int>.OnNext(int value) => Console.WriteLine($"Received: {value}");

        void IObserver<int>.OnError(Exception error) => Console.WriteLine($"Error: {error.Message}");

        void IObserver<int>.OnCompleted() => Console.WriteLine("Sequence Completed.");
    }
}